package com.rabbit;

import java.io.IOException;

import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

/**
 * @author CUIJIAJUN
 * @date 2017年2月15日
 * 
 */
public class RabbitFactory {
	
	public static Connection creatConnection() {
		/**
		 * 创建连接连接到MabbitMQ
		 */
		ConnectionFactory factory = new ConnectionFactory();
		// 设置MabbitMQ所在主机ip或者主机名
		factory.setHost("192.168.1.91");
		// 指定用户 密码
		factory.setUsername("mqtest");
		factory.setPassword("mqtest");
		// 指定端口
		factory.setPort(AMQP.PROTOCOL.PORT);
		// 创建一个连接
		Connection connection = null;
		try {
			connection = factory.newConnection();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return connection;
	}
}
